package com.letu.mq.service.impl;

import com.letu.core.rocketmq.RocketTopicData;
import com.letu.mq.selector.SelectorExpressionTopicOfBusiness;
import com.letu.mq.service.AssembleTopicTagServer;
import com.letu.mq.service.CheckTopicTagServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;

//@Component
public class CheckTopicTagServerImpl implements CheckTopicTagServer {

    @Value("${com.letu.mqSystem}")
    private String mqSystem;

    @Autowired
    AssembleTopicTagServer assembleTopicTagServer;

    @Override
    public String assembleTagOfBuiness() {
        assembleTopicTagServer.initTag();
        return SelectorExpressionTopicOfBusiness.queryStr(mqSystem, RocketTopicData.authTopicTagOfBusiness);
    }

    @Override
    public String assembleTagOfTransaction() {
        return null;
    }

    @Override
    public String assembleTagOfOrderBuiness() {
        return null;
    }
}
